package com.yunc.user.mq.rocketmq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

public interface CustomChannel {

    String INPUT_ORDER_TOPIC = "input-order-topic";
    String OUTPUT_USER_TOPIC = "output-user-topic";

    /**
     * 接受用户信息
     */
    @Input(INPUT_ORDER_TOPIC)
    MessageChannel inputOrderChannel();

    /**
     * 发送消息到订单 Channel 消息
     */
    @Output(OUTPUT_USER_TOPIC)
    MessageChannel outputUserChannel();

}
